package com.cnpc.bds.sdk.sink.kafka.handler.converter;

import com.alibaba.fastjson.JSONObject;
import com.cnpc.bds.sdk.sink.kafka.handler.AbstractHandler;

public class StringToJsonObjConverter extends AbstractHandler<String, JSONObject> {
    @Override
    public JSONObject handle(final String msg) {
        return JSONObject.parseObject(msg);
    }
}
